//package com.Lyf.user.config;
//
//
//import org.springframework.amqp.core.Binding;
//import org.springframework.amqp.core.BindingBuilder;
//import org.springframework.amqp.core.Queue;
//import org.springframework.amqp.core.TopicExchange;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class RabbitMQConfig {
//    //1. 创建exchange - topic
//    @Bean
//    public TopicExchange getTopicExchange(){
//        //三个参数：交换机名字  是否需要持久化(是否随着mq的重新启动交换机还在)  是否被mq自动删除
//        return new TopicExchange("boot-topic-exchange",true,false);
//    }
//
//    //2. 创建queue
//    @Bean
//    public Queue getQueue(){
//       //队列名 队列是否持久化  是否排它(排它之后其他连接就访问不到队列里的数据了) 是否自动删除 创建队列时是否指定其他参数
//        return new Queue("boot-queue",true,false,false,null);
//    }
//
//    //3. 绑定在一起
//    @Bean
//    public Binding getBinding(TopicExchange topicExchange, Queue queue){
//        return BindingBuilder.bind(queue).to(topicExchange).with("*.red.*");
//    }
//}
